# from extensions import celery
from flask_restful import current_app

# from flaskz import cancel_stock_occupy

# from ..constants import CELERY_EXCHANGE_DTC_STOCK_QUEUE


__all__ = ['stock_in_task', 'stock_out_task', 'cancel_stock_occupy_task']


# @celery.context_task(bind=True,
#                      queue=CELERY_EXCHANGE_DTC_STOCK_QUEUE,
#                      default_retry_relay=10,
#                      max_retires=3, ignore_result=True)
def cancel_stock_occupy_task(self, data):
    current_app.logger.info("DTC流水同步失败，加入MQ: <params=%r" % data)
    # cancel_stock_occupy(data)
